<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/9/18
 * Time: 20:18
 */
namespace app\api\controller;



use think\Queue;
use think\Controller;



class Test extends Controller
{



    //测试消息队列
    public function  workman(){

        // 1.当前任务将由哪个类来负责处理。
        //   当轮到该任务时，系统将生成一个该类的实例，并调用其 fire 方法
        $jobHandlerClassName  = 'app\api\job\Test';

        // 2.当前任务归属的队列名称，如果为新队列，会自动创建
        $jobQueueName  	  = "TestJobQueue";

        // 3.当前任务所需的业务数据 . 不能为 resource 类型，其他类型最终将转化为json形式的字符串
        $jobData       	  = [ 'trade_no' => time(), 'create_time' =>time()  ] ;

        // 4.将该任务推送到消息队列，等待对应的消费者去执行

        Queue::later(20,$jobHandlerClassName, $jobData,$jobQueueName);
        $jobData       	  = [ 'trade_no' => time()+1, 'create_time' =>time()  ] ;
        Queue::later(20,$jobHandlerClassName, $jobData,$jobQueueName);
    }

}